20e44cf3feb50328f2856969a4898fa3e07238f3,cdap-hbase-compat-0.94/src/main/java/co/cask/cdap/data2/increment/hbase94/IncrementSummingScanner.java,IncrementSummingScanner,nextInternal,#List#number#String#,128

Before Change


      } else {
        // otherwise (not an increment)
        if (previousIncrement != null) {
          if (sameCell(previousIncrement, cell)) {
            // if qualifier matches previous and this is a long, add to running sum, emit
            runningSum += Bytes.toLong(cell.getBuffer(), cell.getValueOffset());
            // this cell already processed as part of the previous increment

After Change


      } else {
        // otherwise (not an increment)
        if (previousIncrement != null) {
          if (sameCell(previousIncrement, cell) && !KeyValue.isDelete(cell.getType())) {
            // if qualifier matches previous and this is a long, add to running sum, emit
            runningSum += Bytes.toLong(cell.getBuffer(), cell.getValueOffset());
            // this cell already processed as part of the previous increment's sum, so consume it